mysql导入hive

sqoop import –connect jdbc:mysql://IP:3306/dbname –username xxx –password xxx –table table1 –hive-import –hive-overwrite –create-hive-table –hive-table dbname.table1 hive导入mysql

Sqoop export –connect jdbc:mysql://127.0.0.1:3306/dbname –username mysql(mysql用户名) –password 123456(密码) –table student(mysql上的表) –hcatalog-database sopdm(hive上的schema) –hcatalog-table student(hive上的表)

hive导出到文件

1.1. hive>导出到本地

insert overwrite local directory ‘/home/username/a’

row format delimited

fields terminated by ‘,’

select * from dbname.table;

1.2 命令行hive导出

文件导入hive

a.第一步

CREATE TABLE csv_table(a string, b string)

ROW FORMAT SERDE ‘org.apache.Hadoop.hive.serde2.OpenCSVSerde’

WITH SERDEPROPERTIES

( “separatorChar” = “\t”, “quoteChar” = “’”, “escapeChar” = “\”) STORED AS TEXTFILE;

separatorChar：分隔符

quoteChar：引号符

escapeChar：转意符

或者CREATE TABLE csv_table(a string, b string) ROW FORMAT DELIMITED FIELDS TERMINATED BY ‘\001’;

或者CREATE TABLE csv_table(a string, b string) ROW FORMAT DELIMITED FIELDS TERMINATED BY ‘^A’;

b. 第二步

load data local inpath ‘/data/user1.csv’ into table csv_table;